package net.qiqbframework.persisthanding;

import net.qiqbframework.common.Registration;
import net.qiqbframework.messaging.BatchMessage;
import net.qiqbframework.messaging.MessageHandler;

import javax.annotation.Nonnull;

public interface AggregatePersistBus {

    void save(@Nonnull PersistMessage<?> message) throws Exception;



    Registration subscribe(@Nonnull String aggregateNaming, @Nonnull MessageHandler<? super PersistMessage<?>> handler);


}
